package com.xinqing.bigdata.flink.datastream.process;

import com.xinqing.bigdata.flink.datastream.model.Result;
import com.xinqing.bigdata.flink.datastream.model.Student;
import org.apache.flink.api.common.state.ValueStateDescriptor;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.KeyedProcessFunction;
import org.apache.flink.util.Collector;

/**
 * @Author:CHQ
 * @Date:2021/5/12 17:51
 * @Description
 */
public class MyProcess extends KeyedProcessFunction<String, Student, Result> {


    @Override
    public void processElement(Student value, Context ctx, Collector<Result> out) throws Exception {

    }

    @Override
    public void open(Configuration parameters) throws Exception {

       /* new ValueStateDescriptor<>()

        getRuntimeContext().getState()*/

    }

}
